package com.kdzy.lshy.fluxdemo.repository;

import com.kdzy.lshy.fluxdemo.module.MyEvent;
import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
import org.springframework.data.mongodb.repository.Tailable;
import reactor.core.publisher.Flux;

public interface MyEventRepository extends ReactiveMongoRepository<MyEvent, Long> {

    @Tailable // linux的tail命令，被注解的方法将发送无限流，需要注解在返回值为Flux这样的多个元素的Publisher的方法上；
    Flux<MyEvent> findBy(); // findAll()是想要的方法，但是在ReactiveMongoRepository中我们够不着，所以使用findBy()代替。

}
